package com.example.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@CrossOrigin
public class KafkaController {

//    @Autowired
//    private KafkaTemplate kafkaTemplate;
//
//
//    @GetMapping("send")
//    public String sendMsgToKafka(){
//        for (int i = 0; i < 10; i ++){
//            kafkaTemplate.send("user_customer", "csq", "hello kafka : " + i);
//        }
//        return "send ok";
//    }

    @RequestMapping("hello")
    public String hello(){
        System.out.println("hello world");
        return "hello";
    }
}
